package com.streamsets.datacollector.pileline.stage.dto;

/**
 *  HadoopFS配置的业务传输对象
 * @author wengzhonghui
 * @date 2019/10/18 15:08
 */
public class HadoopFSConfigDto {

    String hdfsUri;

    Integer maxRecordsPerFile;

    Integer maxFileSize;

    String idleTimeout;

    String lateRecordsLimit;

    String dataFormat;

    public String getHdfsUri() {
        return hdfsUri;
    }

    public void setHdfsUri(String hdfsUri) {
        this.hdfsUri = hdfsUri;
    }

    public Integer getMaxRecordsPerFile() {
        return maxRecordsPerFile;
    }

    public void setMaxRecordsPerFile(Integer maxRecordsPerFile) {
        this.maxRecordsPerFile = maxRecordsPerFile;
    }

    public Integer getMaxFileSize() {
        return maxFileSize;
    }

    public void setMaxFileSize(Integer maxFileSize) {
        this.maxFileSize = maxFileSize;
    }

    public String getIdleTimeout() {
        return idleTimeout;
    }

    public void setIdleTimeout(String idleTimeout) {
        this.idleTimeout = idleTimeout;
    }

    public String getLateRecordsLimit() {
        return lateRecordsLimit;
    }

    public void setLateRecordsLimit(String lateRecordsLimit) {
        this.lateRecordsLimit = lateRecordsLimit;
    }

    public String getDataFormat() {
        return dataFormat;
    }

    public void setDataFormat(String dataFormat) {
        this.dataFormat = dataFormat;
    }
}
